package mq

type ProducerCfg struct {
	Address []string // Kafka连接信息
}

type ConsumerCfg struct {
	Address   []string // Kafka连接信息
	GroupName string   // 消费组
	ClientID  string   // 客户端标识
	// sarama.OffsetOldest 有消费组时,从消费组的未消费偏移量开始消费, 无消费组时,从头开始消费
	// sarama.OffsetNewest 从当前最新的开始消费
	Messages int64
}
